package com.bbx.flink.demo;

import org.apache.flink.streaming.api.functions.source.SourceFunction;

/**
 * 自定义非并行的源函数
 */
public class NonParallelsources implements SourceFunction {
    private static final long serialVersionUID = 343920843334841897L;

    @Override
    public void run(SourceContext ctx) throws Exception {

    }

    @Override
    public void cancel() {

    }
}
